#include <iostream>
#include <queue>
#include <chrono>
#include <mutex>
#include <thread>
#include <condition_variable>

using namespace std;
using namespace this_thread;
using namespace chrono;

queue<int> Buffer;
mutex mtx;
condition_variable cv;
bool notified = false; // 通知信号

int main() {
    

    // 生产者
    auto producer = [&]() {
        for (int i = 0;; i++) {
            sleep_for(milliseconds(900));
            unique_lock<mutex> lock(mtx);

            cout << "生产者生产了第 " << i << " 个产品"<< endl;
            Buffer.push(i);

            notified = true;
            // 唤醒所有的等待线程
            cv.notify_all();
        }
    };

    // 消费者
    auto consumer = [&]() {
        while (true) {
            unique_lock<mutex> lock(mtx);
            // 避免虚假唤醒
            while (!notified)
                cv.wait(lock);
            // 短暂取消锁，使得生产者有机会在消费者消费空前继续生产
            lock.unlock();
            sleep_for(milliseconds(1000)); // 消费者慢于生产者
            lock.lock();
            while (!Buffer.empty()) {
                cout << "消费者消费了第 " << Buffer.front() << " 个产品"<< endl;
                Buffer.pop();
            }
            notified = false;
        }
    };

    // 分别在不同的线程中运行
    thread p(producer);
    thread cs[10];
    for (int i = 0; i < 10; ++i)
        cs[i] = thread(consumer);
    p.join();
    for (int i = 0; i < 10; ++i)
        cs[i].join();
    return 0;
}
